package mapreduce;

import java.io.BufferedWriter;
import java.io.IOException;
/**
 * This Class is for Disk Management. If user choose disk-base processing. This Class will be base class of
 * disk management.
 * @author Songbo Liao
 *
 * @param <KEYOUT>
 * @param <VALUEOUT>
 */
public class DiskManager<KEYOUT,VALUEOUT> implements Manager<KEYOUT, VALUEOUT>{

	protected BufferedWriter bw;
	protected String Jobdir;

	public DiskManager(String Jobdir) throws IOException {
		this.Jobdir = Jobdir;

	}
	@Override
	public void close() {

		try {
			bw.close();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
	
    /*
     * write <key,value> to disk
     * @see mapreduce.Manager#write(java.lang.Object, java.lang.Object)
     */
	public void write(KEYOUT key, VALUEOUT value) {
		// TODO Auto-generated method stub
		
	}

}
